/**
 * 创建websoket服务器
 */
// 引入WebSocket模块
const WebSocket = require('ws');
// 创建WebSocket服务器，监听8080端口
let port = 2200

const wss = new WebSocket.Server({ port: port });

//所有客户端用户
var clents = new Map();
//数据
var data = [];

// 监听连接事件
wss.on('connection', function connection(ws) {
    // 监听消息事件
    clents.set(ws);
    ws.on('message', function incoming(message) {
        let data = JSON.parse(message);
        console.log(data)
        if(data.type === 'login'){
        }else if(data.type === "message"){
            Array.from(clents.keys()).forEach((wss,index)=>{
                wss.send(JSON.stringify(Object.assign(data,{time: new Date().getFullYear() +" "+ new Date().toLocaleTimeString()})))
            })
        }
    });
})




